package com.burges.net.dataStream.codeRuler.dataInputStream.outerDS;

import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

import java.util.Properties;

/**
 * 创建人    BurgessLee
 * 创建时间   2020/1/26
 * 描述      以Kafka为例介绍的外部数据源
 */
public class KafkaEventDataSourceJava {

    public static void main(String[] args) {
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        //定义参数
        Properties properties = new Properties();
        properties.setProperty("boostrap.servers","localhost:9092");
        //only required for Kafka 0.8
        properties.setProperty("zookeeper.connect", "localhost:2181");
        properties.setProperty("group.id", "test");

//        env.addSource(new FlinkKafkaConsumer010<String>(properties.getProperty("input-data-topic"),
//                new SimpleStringSchema(),
//                properties));


    }

}
